<?php
/**
 * Created by PhpStorm.
 * User: tangzhixing
 * Date: 2021/4/6
 * Time: 11:54
 */
//开启消息队列进程的主文件

require  '../vendor/autoload.php';

/** @var \DI\Container $container */
$container = require '../bootstrap/app.php';

$data = $container->get('queue');
$delay_queue = $container->get('delay_queue');

$queue = $container->make(
    \Asf\MessageQueue\RedisMessageQueue::class
);
//foreach ($data as $k => $v){
//    $data[$k] = new $v;
//}
$queue->run($data, $delay_queue);